#  -*-   coding:utf-8  -*-
#引包
import pymysql
import sys
sys.path.append(r'D:\ceshi_ruanjian\pychram_sq_work\c22035_git')
#创建类
class  db_mysql():
    #创建构造方法
    def  __init__(self,host,user,password,db):
        #设置私有属性
        self.__host = host
        self.__user = user
        self.__password = password
        self.__db = db
    #设置私有方法  主做连接
    def __lj(self):
        db = pymysql.connect(host=self.__host, user=self.__user, password=self.__password, db=self.__db, charset='utf8',cursorclass=pymysql.cursors.DictCursor)
        return db
    #用于  DML
    def  getDML(self,sql):
        #调用连接
        db = self.__lj()
        #打开游标
        cur =  db.cursor()
        #准备sql语句
        index = 0
        #发送sql语句
        try:
            index = cur.execute(sql)
        except:
            #事务的回滚
            db.rollback()
        else:
            #提交事务
            db.commit()
        finally:
            #关闭数据库连接
            db.close()
        return  index#返回数据库所影响的条目数

    #用于查询使用
    def  getQuery(self,sql):
        # 调用连接
        db = self.__lj()
        # 打开游标
        cur = db.cursor()
        # 准备sql语句
        try:
             cur.execute(sql)
             tuples = cur.fetchall()
        finally:
            # 关闭数据库连接
            db.close()
        return list(tuples)#把查询结果返回去
